package cn.itsource.utils;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * @Author: CTL
 * @Description: mq的连接通道
 * @DateTime: 2023年06月13日 18:16
 */

public class RabbitMQUtil {
    /**
    * @description: 接连通道
    * @author: CTL
    * @date: 2023/6/13 18:19
    * @param 无
    * @return Channel  一个mq通道
    */
    public static Channel getchannel(){
        Channel channel=null;
        try {
            // 1.创建连接工厂
            ConnectionFactory factory = new ConnectionFactory();
            // 2.设置连接地址
            factory.setHost("127.0.0.1");
            // 3.创建一个连接对象
            Connection connection = factory.newConnection();
            // 4.从连接对象中创建一个通道
            channel = connection.createChannel();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
        return channel;
    }
}
